package com.niit.mobileDevide.operatesystem;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Partitioner;

public class OperateSystemPartitioner extends Partitioner<Text, Text> {

    @Override
    public int getPartition(Text key, Text value, int numPartitions) {
        // 根据操作系统进行分区，假设键是以OS1或OS2开头
        if (key.toString().startsWith("OS1")) {
            return 0; // 操作系统1分配到第一个分区
        } else if (key.toString().startsWith("OS2")) {
            return 1; // 操作系统2分配到第二个分区
        } else {
            // 对于无效的操作系统，分配到默认分区0
            return 0;
        }
    }
}